#include "BlockQueue.hpp"
#include "Thread.hpp"
#include <string>
#include <vector>
#include <unistd.h>

using namespace ThreadModule;
using namespace std;





// void StartProductor(vector<Thread<BlockQueue<int>>> threads,int num,BlockQueue<int> bq)
// {

// }


int main()
{
    //先创建一个阻塞队列
    BlockQueue<int> *bq=new BlockQueue<int>(5);//容量为5
    //创建一个存放阻塞队列的线程数组
    vector<Thread<BlockQueue<int>>> threads;

    //启动生产者线程函数
    StartProductor();
    //启动消费者线程函数
    StartConsumer();
    //等待所以线程
    WaitAllThread();

    return 0;
}